package com.sltx.controller;

import com.alibaba.fastjson.JSON;
import com.sltx.controller.base.BaseController;
import com.sltx.mapper.NingxiaMapper;
import com.sltx.util.Conversion;
import com.sltx.util.PageData;
import net.sf.json.JSONObject;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.annotation.Configuration;
import org.springframework.scheduling.annotation.EnableScheduling;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.ResponseBody;

import java.io.OutputStream;
import java.net.HttpURLConnection;
import java.net.MalformedURLException;
import java.net.URL;
import java.time.DayOfWeek;
import java.time.LocalDate;
import java.time.temporal.ChronoUnit;
import java.time.temporal.TemporalAdjusters;
import java.util.*;


@Controller
@ResponseBody
@EnableScheduling
@RequestMapping("/ningxia")
@Component
@Configuration
public class NingxiaContriller extends BaseController {


    @Autowired
    private NingxiaMapper ningxiaMapper;


    //定时任务
    //@Scheduled(cron = "0 00 15 ? * MON-FRI")
    public void taskNX() {
        PageData pd = new PageData();
        HashMap<String, Object> map1 = null;
        HashMap<String, Object> map2 = new HashMap<>();
        String jsonString = null;
        //TODO 宁夏
        String url = "http://36.103.192.84:8280/jeecg-boot/appInterface/dayData/acceptDayData";
        //TODO 自测
        //String url = "http://192.168.31.31:20081/KXX/receive-data";
        URL obj = null;
        try {
            obj = new URL(url);
        } catch (MalformedURLException e) {
            throw new RuntimeException(e);
        }
        Map<String, Object> map = new HashMap<>();

        // 获取今天的日期
        LocalDate today = LocalDate.now();
        //计算今天到下一个周五的天数
        //如果今天是周五或周六或周日,需要找到下一个周五
        LocalDate nextFriday = today.with(TemporalAdjusters.nextOrSame(DayOfWeek.FRIDAY));
        //使用ChronoUnit来计算两个日期之间的天数
        long daysUntilNextFriday = ChronoUnit.DAYS.between(today, nextFriday);
        //如果今天是周五
        if (today.getDayOfWeek() == DayOfWeek.FRIDAY) {
            int numentname = ningxiaMapper.getCountEntname();
            pd.put("num", numentname);
        } else {
        int numentname = ningxiaMapper.getCountEntname();
        //随机生成5以内的数字
        Random random = new Random();
        long num = numentname / (daysUntilNextFriday + 1L);//平均分条数
        int randomNumber = (int) (random.nextInt(20) + num) - 10;
        pd.put("num", randomNumber);
        }
        /*// 获取今天的日期
        LocalDate today = LocalDate.now();
        // 计算下一个周六的日期
        LocalDate nextSaturday = today.with(TemporalAdjusters.next(DayOfWeek.SATURDAY));
        // 计算两个日期之间的天数差
        long daysUntilNextSaturday = ChronoUnit.DAYS.between(today, nextSaturday);
        //如果今天是周六就全部推送
        if (today.getDayOfWeek() == DayOfWeek.SATURDAY) {
            int numentname = ningxiaMapper.getCountEntname();
            pd.put("num", numentname);
        } else {
            int numentname = ningxiaMapper.getCountEntname();
            //随机生成5以内的数字
            Random random = new Random();
            long num = numentname / (daysUntilNextSaturday + 1L);//平均分条数
            int randomNumber = (int) (random.nextInt(20) + num) - 10;
            pd.put("num", randomNumber);
        }*/
        //查询统一社会信用代码pd为map格式
        List<String> uniscids = ningxiaMapper.getEntnames(pd);
        for (String uniscid : uniscids) {
            pd.put("entName", uniscid);
            //根据社会统一信用代码查询企业名pd为map格式
            String entName = ningxiaMapper.getEntname(pd);
            pd.put("qiyeming", entName);
            //企业地理位置接口
            JSONObject getGeoPositionInfo1 = Conversion.getServiceData("getGeoPositionInfo", pd);
            List<Map<String, Object>> GeoPositionInfo1 = getGeoPositionInfo1.getJSONArray("RESULTDATA");
            String DOM = null;
            for (Map<String, Object> stringObjectMap : GeoPositionInfo1) {
                DOM = stringObjectMap.get("DOM").toString();
            }

            //如果没有注册地址就不推送
            if (DOM == null || DOM.isEmpty()) {
                //记录日志pd为map格式
                ningxiaMapper.logEntname(pd);
            } else {
                try {
                    //企业地理位置接口
                    JSONObject getGeoPositionInfo = Conversion.getServiceData("getGeoPositionInfo", pd);
                    List<Map<String, Object>> GeoPositionInfo = getGeoPositionInfo.getJSONArray("RESULTDATA");
                    //企业基本信息接口
                    JSONObject getRegisterInfo = Conversion.getServiceData("getRegisterInfo", pd);
                    List<Map<String, Object>> RegisterInfo = getRegisterInfo.getJSONArray("RESULTDATA");
                    //企业联系方式接口
                    JSONObject getEntContactInfo = Conversion.getServiceData("getEntContactInfo", pd);
                    List<Map<String, Object>> EntContactInfo = getEntContactInfo.getJSONArray("RESULTDATA");
                    //企业基本信息
                    if (RegisterInfo.isEmpty()) {
                        map.put("INDUSTRYCONAME", "");//国民经济代码名称(行业领域)
                        map.put("ORGCODES", "");//组织机构代码
                        map.put("REGNO", "");//注册号统一社会信用代码的第九位截九位(从索引8开始不包括索引17)
                        map.put("CREDITCODE", "");//统一社会信用代码
                        pd.put("uniscid", "");//将社会统一信用代码存入日志
                        map.put("OPTO", "");//经营期限至
                        map.put("OPFROM", "");//经营期限自
                        map.put("ENTNAME", "");//企业名称
                        map.put("REGCAP", "");//注册资本（企业:万元）
                        map.put("ESDATE", "");//成立日期
                        map.put("FRNAME", "");//法定代表人/负责人/执行事务合伙人
                        map.put("REGORG", "");//登记机关
                        map.put("ENTSTATUS", "");//经营状态
                        map.put("ENTTYPE", "");//企业类型
                        map.put("REGCAPCUR", "");//注册资本币种
                        map.put("REVDATE", "");//吊销日期
                        map.put("CANDATE", "");//注销日期
                        map.put("ZSOPSCOPE", "");//经营业务范围
                        map.put("ENTNAME_OLD", "");//曾用名
                        map.put("APPRDATE", "");//核准日期
                        map.put("DOM", "");//地址
                    } else {
                        for (Map<String, Object> rg : RegisterInfo) {
                            if (!rg.get("DOM").toString().isEmpty()) {
                                map.put("INDUSTRYCONAME", rg.get("INDUSTRY"));//国民经济代码名称(行业领域)
                                map.put("ORGCODES", rg.get("ORGID"));//组织机构代码
                                map.put("REGNO", rg.get("SHXYDM").toString().substring(8, 17));//注册号统一社会信用代码的第九位截九位(从索引8开始不包括索引17)
                                map.put("CREDITCODE", rg.get("SHXYDM"));//统一社会信用代码
                                pd.put("uniscid", rg.get("SHXYDM"));//将社会统一信用代码存入日志
                                map.put("OPTO", rg.get("OPTO"));//经营期限至
                                map.put("OPFROM", rg.get("OPFROM"));//经营期限自
                                map.put("ENTNAME", rg.get("ENTNAME"));//企业名称
                                map.put("REGCAP", rg.get("REGCAP"));//注册资本（企业:万元）
                                map.put("ESDATE", rg.get("ESDATE"));//成立日期
                                map.put("FRNAME", rg.get("FRDB"));//法定代表人/负责人/执行事务合伙人
                                map.put("REGORG", rg.get("REGORG"));//登记机关
                                map.put("ENTSTATUS", rg.get("ENTSTATUS"));//经营状态
                                map.put("ENTTYPE", rg.get("ENTTYPE"));//企业类型
                                map.put("REGCAPCUR", rg.get("REGCAPCUR"));//注册资本币种
                                map.put("REVDATE", rg.get("REVDATE"));//吊销日期
                                map.put("CANDATE", rg.get("CANDATE"));//注销日期
                                map.put("ZSOPSCOPE", rg.get("OPSCOPE"));//经营业务范围
                                map.put("ENTNAME_OLD", rg.get("OLDNAME"));//曾用名
                                map.put("APPRDATE", rg.get("APPRDATE"));//核准日期
                                map.put("DOM", rg.get("DOM"));//地址
                            }
                        }
                    }
                    //企业联系方式接口
                    if (EntContactInfo.isEmpty()) {
                        map.put("TEL", "");//电话
                        map.put("EMAIL", "");//邮箱
                    } else {
                        StringJoiner contact_type = new StringJoiner(",");
                        StringJoiner contact = new StringJoiner(",");
                        for (int i = 0; i < EntContactInfo.size(); i++) {
                            //如果是电子邮箱
                            if (EntContactInfo.get(i).get("CONTACT_TYPE").toString().equals("电子邮箱")) {
                                // 电子邮箱
                                contact_type.add(EntContactInfo.get(i).get("CONTACT").toString());
                            } else {
                                // 电话
                                contact.add(EntContactInfo.get(i).get("CONTACT").toString());//电话
                            }
                        }
                        map.put("TEL", contact.toString());//电话
                        map.put("EMAIL", contact_type.toString());//邮箱
                    }
                    //企业地理位置接口
                    if (GeoPositionInfo.isEmpty()) {
                        map.put("REGORGPROVINCE", "");//所在省份
                        map.put("REGORGCITY", "");//所在城市
                        map.put("REGORGDISTRICT", "");//所在区/县
                        map.put("COORDINATE", "");//高德坐标(经纬度)
                        //判断企业地址中是否包含"宁东能源化工基地"
                    } else if (DOM.contains("宁东能源化工基地")) {
                        for (Map<String, Object> gp : GeoPositionInfo) {
                            map.put("REGORGPROVINCE", gp.get("LL_PROVINCE"));//所在省份
                            if (gp.get("LL_CITY").equals("银川市") && gp.get("LL_DISTRICT").equals("灵武市")) {
                                map.put("REGORGCITY", gp.get("LL_CITY"));//所在城市
                                map.put("REGORGDISTRICT", gp.get("LL_DISTRICT"));//所在区/县
                                if (gp.get("JWD") != null || !gp.get("JWD").toString().isEmpty()) {
                                    map.put("COORDINATE", gp.get("JWD").toString().replace("东经：", "").replace(" 北纬：", ","));//高德坐标(经纬度)
                                } else {
                                    map.put("COORDINATE", "");//高德坐标(经纬度)
                                }
                            } else {
                                map.put("REGORGCITY", "银川市");//所在城市
                                map.put("REGORGDISTRICT", "灵武市");//所在区/县
                                map.put("COORDINATE", "");//高德坐标(经纬度)
                            }
                        }
                    } else {
                        for (Map<String, Object> gp : GeoPositionInfo) {
                            map.put("REGORGPROVINCE", gp.get("LL_PROVINCE"));//所在省份
                            map.put("REGORGCITY", gp.get("LL_CITY"));//所在城市
                            map.put("REGORGDISTRICT", gp.get("LL_DISTRICT"));//所在区/县
                            if (gp.get("JWD") != null || !gp.get("JWD").toString().isEmpty()) {
                                map.put("COORDINATE", gp.get("JWD").toString().replace("东经：", "").replace(" 北纬：", ","));//高德坐标(经纬度)
                            } else {
                                map.put("COORDINATE", "");//高德坐标(经纬度)
                            }
                        }
                    }
                    map1 = new HashMap<>();
                    map1.put("F_NX_BASIC", map);
                    String jsonString1 = JSON.toJSONString(map1);
                    byte[] bytes1 = jsonString1.getBytes("UTF-8");
                    // 加密
                    byte[] encodedBytes = Base64.getEncoder().encode(bytes1);
                    String encoded = new String(encodedBytes);
                    map2.put("dataStr", encoded);
                    jsonString = JSON.toJSONString(map2);
                    //打开URL连接
                    HttpURLConnection conn = (HttpURLConnection) obj.openConnection();
                    conn.setRequestMethod("POST");
                    //在发送POST请求时，通常需要设置一些请求头的信息，例如设置Content-Type为application/json。使用连接对象的setRequestProperty()方法来设置请求头的信息。
                    conn.setRequestProperty("Content-Type", "application/json");
                    // 配置appId和authKey
                    conn.setRequestProperty("appId", "1604739245");
                    conn.setRequestProperty("authKey", "AqnXkp4B9b9YCY3uLKLkBCEa3vllRD98");
                    //允许输出
                    conn.setDoOutput(true);
                    try (OutputStream os = conn.getOutputStream()) {
                        byte[] input = jsonString.getBytes("utf-8");
                        os.write(input, 0, input.length); // 写入数据到输出流
                    }
                    // 获取响应码
                    int responseCode = conn.getResponseCode();
                    System.out.println("POST Response Code :: " + responseCode);
                    pd.put("code", responseCode);
                    //推送过之后日志pd为map格式
                    ningxiaMapper.logEntname2(pd);
                    //然后将此企业状态设置为1pd为map格式
                    ningxiaMapper.upsfts(pd);
                    Random random1 = new Random();
                    int millisecond = random1.nextInt(3000);
                    System.out.println("随机睡眠毫秒数====>" + millisecond);// 生成0到5000之间的整数，表示毫秒数
                    Thread.sleep(millisecond);//随机睡眠秒数
                    conn.disconnect();
                } catch (Exception e) {
                    System.out.println(e);
                }
            }
        }
        //查看今天推送成功的为多少条
        Integer size = ningxiaMapper.getSizeTuisong();
        System.out.println("今日推送数据" + size + "条数据");
    }


    @RequestMapping("/ningxiaenterpriseData")
    public Object Ningxiaenterprisedata() {
        HashMap<String, Object> map1 = null;
        HashMap<String, Object> map2 = new HashMap<>();
        String jsonString = null;
        //String url = "http://36.103.192.84:8280/jeecg-boot/appInterface/dayData/acceptDayData";
        String url = "http://192.168.31.31:20081/KXX/receive-data";
        URL obj = null;
        try {
            obj = new URL(url);
        } catch (MalformedURLException e) {
            throw new RuntimeException(e);
        }
        Map<String, Object> map = new HashMap<>();
        PageData pd = this.getPageData();

        /*// 获取今天的日期
        LocalDate today = LocalDate.now();
        //计算今天到下一个周五的天数
        //如果今天是周五或周六或周日,需要找到下一个周五
        LocalDate nextFriday = today.with(TemporalAdjusters.nextOrSame(DayOfWeek.FRIDAY));
        //使用ChronoUnit来计算两个日期之间的天数
        long daysUntilNextFriday = ChronoUnit.DAYS.between(today, nextFriday);
        //如果今天是周五
        if (today.getDayOfWeek() == DayOfWeek.FRIDAY) {
            int numentname = ningxiaMapper.getCountEntname();
            pd.put("num", numentname);
        } else {
            //查询需要推送的企业有多少
            int numentname = ningxiaMapper.getCountEntname();
            //随机生成5以内的数字
            Random random = new Random();
            long num = numentname / (daysUntilNextFriday + 1L);//平均分条数
            int randomNumber = (int) (random.nextInt(20) + num) - 10;
            pd.put("num", randomNumber);
        }*/

        //查询统一社会信用代码
//        List<String> uniscids = ningxiaMapper.getEntnames(pd);
//        for (String uniscid : uniscids) {
//            pd.put("entName", uniscid);
        //根据社会统一信用代码查询企业名
        String entName = ningxiaMapper.getEntname(pd);
        //pd.put("qiyeming", entName);
        pd.put("entName", pd.get("entName"));
        //企业地理位置接口
        JSONObject getGeoPositionInfo1 = Conversion.getServiceData("getGeoPositionInfo", pd);
        List<Map<String, Object>> GeoPositionInfo1 = getGeoPositionInfo1.getJSONArray("RESULTDATA");
        String DOM = null;
        for (Map<String, Object> stringObjectMap : GeoPositionInfo1) {
            DOM = stringObjectMap.get("DOM").toString();
        }
        //如果没有注册地址就不推送
        if (DOM == null || DOM.isEmpty()) {
            //记录日志
            //ningxiaMapper.logEntname(pd);
        } else {
            try {
                //企业地理位置接口
                JSONObject getGeoPositionInfo = Conversion.getServiceData("getGeoPositionInfo", pd);
                List<Map<String, Object>> GeoPositionInfo = getGeoPositionInfo.getJSONArray("RESULTDATA");
                //企业基本信息接口
                JSONObject getRegisterInfo = Conversion.getServiceData("getRegisterInfo", pd);
                List<Map<String, Object>> RegisterInfo = getRegisterInfo.getJSONArray("RESULTDATA");
                //企业联系方式接口
                JSONObject getEntContactInfo = Conversion.getServiceData("getEntContactInfo", pd);
                List<Map<String, Object>> EntContactInfo = getEntContactInfo.getJSONArray("RESULTDATA");
                //企业基本信息
                if (RegisterInfo.isEmpty()) {
                    map.put("INDUSTRYCONAME", "");//国民经济代码名称(行业领域)
                    map.put("ORGCODES", "");//组织机构代码
                    map.put("REGNO", "");//注册号统一社会信用代码的第九位截九位(从索引8开始不包括索引17)
                    map.put("CREDITCODE", "");//统一社会信用代码
                    pd.put("uniscid", "");//将社会统一信用代码存入日志
                    map.put("OPTO", "");//经营期限至
                    map.put("OPFROM", "");//经营期限自
                    map.put("ENTNAME", "");//企业名称
                    map.put("REGCAP", "");//注册资本（企业:万元）
                    map.put("ESDATE", "");//成立日期
                    map.put("FRNAME", "");//法定代表人/负责人/执行事务合伙人
                    map.put("REGORG", "");//登记机关
                    map.put("ENTSTATUS", "");//经营状态
                    map.put("ENTTYPE", "");//企业类型
                    map.put("REGCAPCUR", "");//注册资本币种
                    map.put("REVDATE", "");//吊销日期
                    map.put("CANDATE", "");//注销日期
                    map.put("ZSOPSCOPE", "");//经营业务范围
                    map.put("ENTNAME_OLD", "");//曾用名
                    map.put("APPRDATE", "");//核准日期
                    map.put("DOM", "");//地址
                } else {
                    for (Map<String, Object> rg : RegisterInfo) {
                        if (!rg.get("DOM").toString().isEmpty()) {
                            map.put("INDUSTRYCONAME", rg.get("INDUSTRY"));//国民经济代码名称(行业领域)
                            map.put("ORGCODES", rg.get("ORGID"));//组织机构代码
                            map.put("REGNO", rg.get("SHXYDM").toString().substring(8, 17));//注册号统一社会信用代码的第九位截九位(从索引8开始不包括索引17)
                            map.put("CREDITCODE", rg.get("SHXYDM"));//统一社会信用代码
                            pd.put("uniscid", rg.get("SHXYDM"));//将社会统一信用代码存入日志
                            map.put("OPTO", rg.get("OPTO"));//经营期限至
                            map.put("OPFROM", rg.get("OPFROM"));//经营期限自
                            map.put("ENTNAME", rg.get("ENTNAME"));//企业名称
                            map.put("REGCAP", rg.get("REGCAP"));//注册资本（企业:万元）
                            map.put("ESDATE", rg.get("ESDATE"));//成立日期
                            map.put("FRNAME", rg.get("FRDB"));//法定代表人/负责人/执行事务合伙人
                            map.put("REGORG", rg.get("REGORG"));//登记机关
                            map.put("ENTSTATUS", rg.get("ENTSTATUS"));//经营状态
                            map.put("ENTTYPE", rg.get("ENTTYPE"));//企业类型
                            map.put("REGCAPCUR", rg.get("REGCAPCUR"));//注册资本币种
                            map.put("REVDATE", rg.get("REVDATE"));//吊销日期
                            map.put("CANDATE", rg.get("CANDATE"));//注销日期
                            map.put("ZSOPSCOPE", rg.get("OPSCOPE"));//经营业务范围
                            map.put("ENTNAME_OLD", rg.get("OLDNAME"));//曾用名
                            map.put("APPRDATE", rg.get("APPRDATE"));//核准日期
                            map.put("DOM", rg.get("DOM"));//地址
                        }
                    }
                }
                //企业联系方式接口

                if (EntContactInfo.isEmpty()) {
                    map.put("TEL", "");//电话
                    map.put("EMAIL", "");//邮箱
                } else {
                    StringJoiner contact_type = new StringJoiner(",");
                    StringJoiner contact = new StringJoiner(",");
                    for (int i = 0; i < EntContactInfo.size(); i++) {
                        //如果是电子邮箱
                        if (EntContactInfo.get(i).get("CONTACT_TYPE").toString().equals("电子邮箱")) {
                            // 电子邮箱
                            contact_type.add(EntContactInfo.get(i).get("CONTACT").toString());
                        } else {
                            // 电话
                            contact.add(EntContactInfo.get(i).get("CONTACT").toString());//电话
                        }
                    }
                    map.put("TEL", contact.toString());//电话
                    map.put("EMAIL", contact_type.toString());//邮箱
                }
                //企业地理位置接口
                if (GeoPositionInfo.isEmpty()) {
                    map.put("REGORGPROVINCE", "");//所在省份
                    map.put("REGORGCITY", "");//所在城市
                    map.put("REGORGDISTRICT", "");//所在区/县
                    map.put("COORDINATE", "");//高德坐标(经纬度)
                } else if (DOM.contains("宁东能源化工基地")) {
                    for (Map<String, Object> gp : GeoPositionInfo) {
                        map.put("REGORGPROVINCE", gp.get("LL_PROVINCE"));//所在省份
                        if (gp.get("LL_CITY").equals("银川市") && gp.get("LL_DISTRICT").equals("灵武市")) {
                            map.put("REGORGCITY", gp.get("LL_CITY"));//所在城市
                            map.put("REGORGDISTRICT", gp.get("LL_DISTRICT"));//所在区/县
                            map.put("COORDINATE", gp.get("JWD").toString().replace("东经：", "").replace(" 北纬：", ","));//高德坐标(经纬度)
                        } else {
                            map.put("REGORGCITY", "银川市");//所在城市
                            map.put("REGORGDISTRICT", "灵武市");//所在区/县
                            map.put("COORDINATE", "");//高德坐标(经纬度)
                        }
                    }
                } else {
                    for (Map<String, Object> gp : GeoPositionInfo) {
                        map.put("REGORGPROVINCE", gp.get("LL_PROVINCE"));//所在省份
                        map.put("REGORGCITY", gp.get("LL_CITY"));//所在城市
                        map.put("REGORGDISTRICT", gp.get("LL_DISTRICT"));//所在区/县
                        map.put("COORDINATE", gp.get("JWD").toString().replace("东经：", "").replace(" 北纬：", ","));//高德坐标(经纬度)
                    }
                }
                map1 = new HashMap<>();
                map1.put("F_NX_BASIC", map);
                String jsonString1 = JSON.toJSONString(map1);
                byte[] bytes1 = jsonString1.getBytes("UTF-8");
                // 加密
                byte[] encodedBytes = Base64.getEncoder().encode(bytes1);
                String encoded = new String(encodedBytes);
                map2.put("dataStr", encoded);
                jsonString = JSON.toJSONString(map2);
                //打开URL连接
                HttpURLConnection conn = (HttpURLConnection) obj.openConnection();
                conn.setRequestMethod("POST");
                //在发送POST请求时，通常需要设置一些请求头的信息，例如设置Content-Type为application/json。使用连接对象的setRequestProperty()方法来设置请求头的信息。
                conn.setRequestProperty("Content-Type", "application/json");
                // 配置appId和authKey
                conn.setRequestProperty("appId", "1604739245");
                conn.setRequestProperty("authKey", "AqnXkp4B9b9YCY3uLKLkBCEa3vllRD98");
                //允许输出
                conn.setDoOutput(true);
                try (OutputStream os = conn.getOutputStream()) {
                    byte[] input = jsonString.getBytes("utf-8");
                    os.write(input, 0, input.length); // 写入数据到输出流
                }
                // 获取响应码
                int responseCode = conn.getResponseCode();
                System.out.println("POST Response Code :: " + responseCode);
                pd.put("code", responseCode);
                //TODO 暂时注释
                //推送过之后日志
                //ningxiaMapper.logEntname2(pd);
                //然后将此企业状态设置为1
                //ningxiaMapper.upsfts(pd);
                Random random = new Random();
                int millisecond = random.nextInt(3000);
                System.out.println("随机睡眠毫秒数====>" + millisecond);// 生成0到5000之间的整数，表示毫秒数
                Thread.sleep(millisecond);//随机睡眠秒数
                conn.disconnect();
            } catch (Exception e) {
                System.out.println(e);
            }
        }
//                }
        //查看今天推送成功的为多少条
        Integer size = ningxiaMapper.getSizeTuisong();
        return "今日推送数据" + size + "条数据";
    }


}
